/**
 * Copyright (C) 2013 SHANGHAI VOLKSWAGEN, All rights reserved.
 * License version 1.0, a copy of which has been included with this.
 *
 * @File name：com.market.order.server.controller.AliPayController
 * @Create on：2024/3/3
 * @Author：liuchang
 */
package com.market.order.server.controller;

import cn.hutool.json.JSONObject;
import com.alipay.api.AlipayApiException;
import com.alipay.api.AlipayClient;
import com.alipay.api.DefaultAlipayClient;
import com.alipay.api.internal.util.AlipaySignature;
import com.alipay.api.request.AlipayTradePagePayRequest;
import com.market.order.common.domain.Alipay;
import com.market.order.common.domain.AlipayConfig;
import com.market.order.common.domain.TOrderDetail;
import com.market.order.server.mapper.TOrderMapper;
import com.market.order.server.service.ITOrderDetailService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

/**
 * <p>ClassName：AliPayController</p >
 * <p>Description：</p >
 * <p>Author：liuchang</p >
 * <p>Date：2024/3/3</p >
 */
@RestController
@RequestMapping("/alipay")
public class AliPayController {
    private static final String GATEWAY_URL = "https://openapi-sandbox.dl.alipaydev.com/gateway.do";
   private static final String FORMAT = "JSON";
   private static final String CHARSET = "UTF-8";
   //签名方式
   private static final String SIGN_TYPE = "RSA2";

    @Resource
    private AlipayConfig aliPayConfig;
    @Autowired
    TOrderMapper tOrderMapper;
    @Autowired
    private ITOrderDetailService tOrderDetailService;

        //    @Resource
//    private OrdersMapper ordersMapper;
// http://5r3zhz.natappfree.cc/alipay/pay?subject=2132&traceNo=103&totalAmount=10;

   @GetMapping("/pay") // ?subject=xxx&traceNo=xxx&totalAmount=xxx
   public void pay(Alipay aliPay, HttpServletResponse httpResponse) throws Exception {
  // 1. 创建Client，通用SDK提供的Client，负责调用支付宝的API



  AlipayClient alipayClient = new DefaultAlipayClient(GATEWAY_URL, aliPayConfig.getAppId(),
  aliPayConfig.getAppPrivateKey(), FORMAT, CHARSET, aliPayConfig.getAlipayPublicKey(), SIGN_TYPE);

   // 2. 创建 Request并设置Request参数
   AlipayTradePagePayRequest request = new AlipayTradePagePayRequest();  // 发送请求的 Request类
   request.setNotifyUrl(aliPayConfig.getNotifyUrl());
   JSONObject bizContent = new JSONObject();
   bizContent.set("out_trade_no", aliPay.getTraceNo());  // 我们自己生成的订单编号
   bizContent.set("total_amount", aliPay.getTotalAmount()); // 订单的总金额
   bizContent.set("subject", aliPay.getSubject());  // 支付的名称
   bizContent.set("product_code", "FAST_INSTANT_TRADE_PAY");  // 固定配置
   request.setBizContent(bizContent.toString());
   request.setReturnUrl(aliPayConfig.getReturnUrl());

   // 执行请求，拿到响应的结果，返回给浏览器
   String form = "";
   try {
    form = alipayClient.pageExecute(request).getBody(); // 调用SDK生成表单
   } catch (AlipayApiException e) {
    e.printStackTrace();
   }
   httpResponse.setContentType("text/html;charset=" + CHARSET);
   httpResponse.getWriter().write(form);// 直接将完整的表单html输出到页面
   httpResponse.getWriter().flush();
   httpResponse.getWriter().close();
       }

    @PostMapping("/notify")  // 注意这里必须是POST接口
 public String payNotify(HttpServletRequest request) throws Exception {
 if (request.getParameter("trade_status").equals("TRADE_SUCCESS")) {
  System.out.println("=========支付宝异步回调========");

  Map<String, String> params = new HashMap<>();
  Map<String, String[]> requestParams = request.getParameterMap();
  for (String name : requestParams.keySet()) {
  params.put(name, request.getParameter(name));
  // System.out.println(name + " = " + request.getParameter(name));
  }

  String outTradeNo = params.get("out_trade_no");
  String gmtPayment = params.get("gmt_payment");
  String alipayTradeNo = params.get("trade_no");


  String sign = params.get("sign");
  String content = AlipaySignature.getSignCheckContentV1(params);
  boolean checkSignature = AlipaySignature.rsa256CheckContent(content, sign, aliPayConfig.getAlipayPublicKey(), "UTF-8"); // 验证签名
  // 支付宝验签
  if (checkSignature) {
  // 验签通过
  System.out.println("交易名称: " + params.get("subject"));
  System.out.println("交易状态: " + params.get("trade_status"));
  System.out.println("支付宝交易凭证号: " + params.get("trade_no"));
  System.out.println("商户订单号: " + params.get("out_trade_no"));
  System.out.println("交易金额: " + params.get("total_amount"));
  System.out.println("买家在支付宝唯一id: " + params.get("buyer_id"));
  System.out.println("买家付款时间: " + params.get("gmt_payment"));
  System.out.println("买家付款金额: " + params.get("buyer_pay_amount"));


  //根据订单id修改订单状态
  tOrderMapper.paysuccess(params.get("out_trade_no"),params.get("total_amount"));
  //根据订单id得到订单信息
   List<TOrderDetail> orderDetails = tOrderDetailService.findDetail(Integer.valueOf(params.get("out_trade_no"))).getData();
   //得到每个订单里的商品的数量
   for (TOrderDetail orderDetail : orderDetails) {
    Integer productId = orderDetail.getProductId();
    Integer productQuantity = orderDetail.getProductQuantity();
    System.out.println(productId);
    //修改库库存
    tOrderMapper.updateInventory(productId,productQuantity);
   }


//
//   // 查询订单
//   QueryWrapper<Orders> queryWrapper = new QueryWrapper<>();
//   queryWrapper.eq("order_id", outTradeNo);
//   Orders orders = ordersMapper.selectOne(queryWrapper);
//
//   if (orders != null) {
//   orders.setAlipayNo(alipayTradeNo);
//   orders.setPayTime(new Date());
//   orders.setState("已支付");
//   ordersMapper.updateById(orders);
//   }
   }
  }
  return "success";
   }




}
